package com.nhjf.mobile.bus.queue;

//@Component
public class EventQueueManager {

	
	public final static String QUEUE_PREFIX = "_FLB_QUEUE";

//	@Autowired
//	private HazelcastInstance hz;
//	@Autowired
//	private ApplicationContext applicationContext;

	/**
	 * 根据事件类型获取事件队列
	 * @param type
	 * @return
	 */
//	public IQueue<FlbEvent<? extends BaseModel>> getQueue(Integer type) {
//		IQueue<FlbEvent<? extends BaseModel>> queue = hz.getQueue(QUEUE_PREFIX + "_EVENTTYPE_" + type);
//		return queue;
//	}
//
//	/**
//	 * 将一个事件消息推送到对应的事件消息队列
//	 * @param event
//	 */
//	public void publishEvent(FlbEvent<? extends BaseModel> event) {
//		getQueue(event.getType()).add(event);
//		logger.info(event.getRemark());
//	}

}
